package amqps

import (
	"context"
	"errors"
	"github.com/streadway/amqp"
)

var NOT_HANDLER_FIND_ERROR = errors.New("没有找到handler")

type MessageHandler func(ctx context.Context, data []byte, delivery *amqp.Delivery) error
